package com.zxq.frame.rabbitmq.config;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;


public interface IRabbitSubscribeHelper {




    /**
     * wen层下发，需要再次包装数据，下发到设备
     * @throws Exception
     */
    @RabbitListener(queues = "${spring.rabbitmq.template.http-channel-queue}")
    void receiveWebChannel(Message message, Channel channel) throws Exception;


    /**
     * 设备层上报，需要解包后，再上传到web层
     * @throws Exception
     */
    @RabbitListener(queues = "${spring.rabbitmq.template.tcp-channel-queue}")
    void receiveNetwork(Message message, Channel channel) throws Exception;




}
